package com.bjpowernode.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

//建立与数据库的连接，然后操作数据库
//使用java.sql.Connection对象操作数据库
//1——需要使用官方提供的数据库驱动来获取java.sql.Connection对象
public class DB {
    //1——MySQL驱动需要第一时间加载到内存
    static {
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            System.out.println("数据库驱动加载失败：" + e.getMessage());
        }
    }
    //2——定义私有静态数据库连接对象java.sql.Connection
    private static Connection cn = null;

    //3——定义公有获取数据库连接对象java.sql.Connection的实例方法
    //获取java.sql.Connection对象
    public static Connection getCn() {
        //数据库连接协议【数据库连接字符串】
        String url="jdbc:mysql://localhost:3306/enterprisedb";
        //数据库登录用户
        String user="root";
        //数据库登录密码
        String password="123456";
        try {
            cn=DriverManager.getConnection(url,user,password);
        } catch (SQLException e) {
            System.out.println("数据库连接协议失败：" + e.getMessage());
        }
        return cn;
    }

    //4——定义公有获取数据库连接对象java.sql.Connection的实例方法
    //关闭java.sql.Connection对象
    public static void closeCn() {
        try {
            if (cn != null && !cn.isClosed()) {
                cn.close();
            }
        } catch (SQLException e) {
            System.out.println("数据库连接对象关闭失败：" + e.getMessage());
        }
    }

}
